
package org.inasnet;

import java.util.concurrent.LinkedBlockingQueue;

public class BytesPackQueue 
{
	public BytesPack poll()
	{
		synchronized( mBytesPackQueue )
		{
			return mBytesPackQueue.poll();
		}
	}
	
	public void add( byte [] audioBytes, int numBytes )
    {
		if( audioBytes == null )
			return;
		
		if( audioBytes.length == 0 || numBytes == 0 )
			return;
		
		synchronized( mBytesPackQueue )
		{
			mBytesPackQueue.add( new BytesPack( audioBytes, numBytes ) );
		}
    }
	
	public void add( byte [] data ) 
	{
		add( data, data.length );
	}
	
	LinkedBlockingQueue< BytesPack > mBytesPackQueue = new LinkedBlockingQueue< BytesPack >();
}
